package com.baijiaoxi.common.model.asyncjob.eventbus;

import com.baijiaoxi.common.model.mq.MQBody;

import java.util.Map;


public interface EventStorage {

    void in(String topic, MQBody data);

    void out(String topic, MQBody data);

    Map<String, MQBody> getAll(String topic);
}
